//package com.xnyzc.lhy.mis.mq;
//
//import com.xnyzc.lhy.common.util.IDUtil;
//import lombok.Data;
//import lombok.ToString;
//import org.apache.rocketmq.client.exception.MQClientException;
//import org.apache.rocketmq.client.producer.DefaultMQProducer;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
///**
// * @Author: huxuekuo
// * @Date: 2019-07-20 17:43
// * @Description:
// */
//
//@Configuration
//@ToString
//@Data
//public class RocketConfig {
//
//
//    @Value("${global.pang.mq.groupNames.consumerPre}")
//    private String consumerGroupName;
//    @Value("${global.pang.mq.nameServerAddr}")
//    private String nameServerAddr;
//    @Value("${global.pang.mq.groupNames.producer}")
//    private String ProducerGroupName;
////    @Value("${global.pang.mq.topics}")
////    private String topic;
//    @Value("${global.pang.mq.tag}")
//    private String tag;
//    private String group;
//    private String topic;
//
//
//    /**
//     * 创建普通消息发送者实例
//     *
//     * @return
//     * @throws MQClientException
//     */
//    @Bean
//    public DefaultMQProducer defaultProducer() throws MQClientException {
//        DefaultMQProducer producer = new DefaultMQProducer(getProducerGroupName());
//        producer.setNamesrvAddr(getNameServerAddr());
//        producer.setVipChannelEnabled(false);
//        producer.setRetryTimesWhenSendAsyncFailed(10);
//        group = IDUtil.nextId() + "";
//        topic= IDUtil.nextId() + "";
//        producer.start();
//        return producer;
//    }
//
//}
